package com.gitee.zhangchenyan.takin.event.producer;

import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;

/**
 * 生产者配置
 *
 * @date 2022/09/15
 */
@Configuration
@Data
public class EventBusProducerConfig {

    /**
     * 卡夫卡引导服务器
     */
    @Value("${takin.kafka.bootstrap-servers:#{null}}")
    private String bootstrapServers;
    /**
     * 重试次数
     * 默认为1
     */
    @Value("${takin.kafka.producer.retries:1}")
    private int retries;
    /**
     * 批量大小
     * 默认16384
     */
    @Value("${takin.kafka.producer.batch-size:16384}")
    private int batchSize;
    /**
     * 生产端缓冲区大小
     * 默认32MB
     */
    @Value("${takin.kafka.producer.buffer-memory:33554432}")
    private int bufferMemory;
    /**
     * ack
     * 应答级别:多少个分区副本备份完成时向生产者发送ack确认(可选0、1、all/-1)
     * 默认为1
     */
    @Value("${takin.kafka.producer.acks:1}")
    private String acks;
}
